package productor;

import consumidor.*;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.logging.Level;
import java.util.logging.Logger;
import red.Cliente;

public class Productor extends Thread{

    Cliente enviador;
    int nombre;
		
	public Productor(String host, int port, int nombre){
        this.nombre = nombre;
        enviador = new Cliente(host, port);
	}

    @Override
	public void run(){
		for(int i = 0; i < 10; i++){
            Elemento elemento = new Elemento(i, nombre);
            enviador.enviar(elemento);
            System.out.println("elemento enviado " + i);
		}
        while(true){
            int a=0;

            BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
            try {
                a = Integer.parseInt(in.readLine());
            } catch (IOException ex) {
                Logger.getLogger(Productor.class.getName()).log(Level.SEVERE, null, ex);
            }

            Elemento elemento = new Elemento(a, nombre);
            enviador.enviar(elemento);
            System.out.println("se envio el elemento " + a);
        }
	}
}
